package com.mlog.njyjy.ndop.monitor.redis;

import java.util.ArrayList;
import java.util.List;
import org.springframework.stereotype.Component;

import com.mlog.njyjy.ndop.monitor.pojo.MessageDO;

import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;

@Component
public class MessageClient extends RedisClient {

	public MessageDO getMsg(String msgKey) {
		String msgstr = get_str_msg(msgKey.replaceAll("\"", ""));
		if (msgstr.isEmpty())
			return null;
		JSONObject obj = JSONUtil.parseObj(msgstr);
		MessageDO msg = JSONUtil.toBean(obj, MessageDO.class);
		msg.setBody(msgstr);
		return msg;
	}
	
	public List<MessageDO> getMsgList(String listKey) {
		List<String> msgKeys = get_list_msg(listKey);
		List<MessageDO> msgs = new ArrayList<>();
		for(String msgKey : msgKeys) {
			msgs.add(getMsg(msgKey));
		}
		return msgs;
	}
}
